import os
import sys
import time
sys.path.append(os.path.dirname(os.path.abspath(__file__)))
# print(os.path.dirname(os.path.abspath(__file__)))
from celery import Celery


app_ = Celery(os.path.abspath(__file__), broker='redis://172.17.0.1:6379/15',backend='redis://172.17.0.1:6379/14')
app_.autodiscover_tasks(['celery_task', 'sftp_service'])
